//package com.electron.power.aio.mod.str;
//
//import org.smartboot.socket.MessageProcessor;
//import org.smartboot.socket.StateMachineEnum;
//import org.smartboot.socket.transport.AioSession;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.http.MediaType;
//import org.springframework.stereotype.Component;
//import org.springframework.web.reactive.function.client.WebClient;
//
//import com.electron.power.model.mod.Mod;
//import com.electron.power.model.mod.ModBodyMap;
//import com.electron.power.model.mod.ModStr;
//
//import lombok.extern.slf4j.Slf4j;
//import reactor.core.publisher.Mono;
//
//@Component
//@Slf4j
//public class ModStringProcessor implements MessageProcessor<ModStr> {
//	@Autowired
//	private WebClient.Builder webClientBuilder;
//
//	@Override
//	public void process(AioSession<ModStr> session, ModStr msg) {
//		log.info("收到客户端的mod信息为:{}", msg);
//		Mono<ModStr> modBody = webClientBuilder.build().post().uri("http://localhost:8100/data/modstr")
//				.contentType(MediaType.APPLICATION_JSON).body(Mono.just(msg), ModStr.class).retrieve()
//				.bodyToMono(ModStr.class);
//		modBody.subscribe(System.out::println);
//		// TODO 发送消息到rabbitMQ.交给项目处理数据.
//		// try {
//		// session.write(mod);
//		// } catch (IOException e) {
//		// e.printStackTrace();
//		// }
//	}
//
//	@Override
//	public void stateEvent(AioSession<ModStr> session, StateMachineEnum stateMachineEnum, Throwable throwable) {
//
//	}
//
//}
